//package com.chen.back.controller;
//
//import com.chen.back.entity.RabbitMq;
////import org.springframework.amqp.rabbit.connection.CorrelationData;
////import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.*;
//import org.springframework.beans.factory.annotation.Autowired;
//
//import javax.servlet.http.HttpServletRequest;
//import java.text.SimpleDateFormat;
//import java.util.Date;
//import java.util.HashMap;
//import java.util.Map;
//import java.util.UUID;
//
///**
// * @author chen
// * @date @{DATE} -21:21
// **/
//
//@RestController
//public class RabbitController {
//
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//
//    @GetMapping("/send")
//    public String send()
//    {
//        System.out.println("信息队列");
//        for (int i=0;i<10;i++)
//        {
//            if(i%2==0)
//            {
//                RabbitMq mq = new RabbitMq();
//                mq.setAge(i);
//                mq.setName("小明-"+i);
//                rabbitTemplate.convertAndSend(" exchange.direct","atguigu",mq);
//            }
//            RabbitMq mq = new RabbitMq();
//            mq.setAge(i);
//            mq.setName("小红-"+i);
//            rabbitTemplate.convertAndSend(" exchange.direct","atguigu",mq);
//
//        }
//        return "ok";
//    }
//
//
//
//    @GetMapping("/sendMessage")
//    public String sendDirectMessage(){
//
//        String messageId = UUID.randomUUID().toString();
//        String messageData = "test message,hello!";
//        String current = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
//        RabbitMq rabbitMq = new RabbitMq();
//        rabbitMq.setName("xiaoming");
//        rabbitMq.setAge(1);
////        Map<String,Object> map = new HashMap<>();
////        map.put("messageId",messageId);
////        map.put("data",messageData);
////        map.put("current",current);
//        rabbitTemplate.convertAndSend("TestDirectExchange", "123",rabbitMq, new CorrelationData(UUID.randomUUID().toString()));
//        return "ok";
//    }
//
//}
